package yz.hdfs;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;

import java.io.IOException;
import java.net.URI;

public class demo1ConnectFileSystem {
    public static void main(String[] args) throws Exception {
        //创建连接
        Configuration entries = new Configuration();
        //这是第一种连接方式
//        entries.set("fs.defaultFS","hdfs://master:9001");
//
//        FileSystem fileSystem = FileSystem.get(entries);

        //第二种连接方式
        FileSystem fileSystem = FileSystem.get(new URI("hdfs://master:9001"), entries);

        System.out.println("连接成功，fileSystem的子实现类"+fileSystem.getClass().getName());
        //连接成功，fileSystem的子实现类org.apache.hadoop.hdfs.DistributedFileSystem

        fileSystem.close();
    }
}
